kafka-topics.sh --bootstrap-server broker-1:9092 --list

kafka-console-consumer.sh --bootstrap-server broker-1:9092 --topic test-topic --from-beginning

kafka-console-consumer.sh --bootstrap-server broker-1:9092 --topic test-topic-spring --from-beginning

kafka-console-consumer.sh --bootstrap-server broker-1:9092 --topic test-topic

kafka-console-consumer.sh --bootstrap-server broker-1:9092 --topic retry-test-topic-dlt --from-beginning
kafka-topics.sh --bootstrap-server broker-1:9092 --describe --topic retry-test-topic-dlt
kafka-console-consumer.sh --bootstrap-server broker-1:9092 --topic retry-test-topic-retry --from-beginning --property print.key=true --property print.offset=true --property print.headers=true
kafka-console-consumer.sh --bootstrap-server broker-1:9092 --topic retry-test-topic-retry --from-beginning --property print.headers=true
kafka-topics.sh --bootstrap-server broker-1:9092 --describe --topic retry-test-topic-retry

kafka-topics.sh --bootstrap-server broker-1:9092 --delete --topic test-topic

kafka-topics.sh --bootstrap-server broker-1:9092 --delete --topic retry-test-topic
kafka-topics.sh --bootstrap-server broker-1:9092 --delete --topic retry-test-topic-dlt
kafka-topics.sh --bootstrap-server broker-1:9092 --delete --topic retry-test-topic-retry-0
kafka-topics.sh --bootstrap-server broker-1:9092 --delete --topic retry-test-topic-retry-1
kafka-topics.sh --bootstrap-server broker-1:9092 --delete --topic temp-topic
kafka-topics.sh --bootstrap-server broker-1:9092 --delete --topic temp-topic-dlt
kafka-topics.sh --bootstrap-server broker-1:9092 --delete --topic temp-topic-retry-0
kafka-topics.sh --bootstrap-server broker-1:9092 --delete --topic temp-topic-retry-1

kafka-topics.sh --bootstrap-server broker-1:9092 --describe --topic test-topic

kafka-console-producer.sh --bootstrap-server broker-1:9092 --topic test-topic

kafka-console-producer.sh --bootstrap-server broker-1:9092 --topic test-topic-2

# 没作用
kafka-consumer-perf-test.sh --topic test-topic --broker-list broker-1:9092 --fetch-max-wait-ms 10000 --fetch-min-bytes 10000000 --messages 10000

kafka-topics.sh --bootstrap-server broker-1:9092 --create --replication-factor 3 --partitions 5 --topic retry-test-topic

kafka-topics.sh --bootstrap-server broker-1:9092 --create --replication-factor 3 --partitions 5 --topic temp-topic